package com.star.common.mq.kafka.core;

import javax.annotation.Nullable;

/**
 * 消息持久化
 *
 * @author zhouhengzhe
 */
public abstract class BaseMessagePersistence {

    /**
     * 消息持久化
     *
     * @param msg 消息
     */
    public abstract <T> void persist(String topic, @Nullable T msg);
}
